package com.dylearn.serve.impl.rabbitmq.listener;

import org.springframework.amqp.rabbit.annotation.RabbitListener;

//@Component
public class MsgListenerDirect {

    //绑定 消息队列
    @RabbitListener(queues = "direct_queue")
    public void receive(String id ){
        System.out.println("处理消息队列 -- direct_queue id" + id);
    }


}
